package com.nulldev.util.uri.yt.broken.util;

public class Observable<T>
{
    final OnSubscribe<T> onSubscribe;
    
    protected Observable(final OnSubscribe<T> f) {
        this.onSubscribe = f;
    }
    
    public interface OnSubscribe<T> extends Action1<Subscriber<? super T>>
    {
    }
}
